package com.fulin.thread.queue.delayqueue;
/**
*
* @description 
* @auther fulin16@crnet.com.hk
* @since 2019年4月13日 下午3:54:30
*
*/
public class Producer {
	public void execute(){
		new Thread(new Runnable() {
			
			@Override
			public void run() {
				for(int i = 1; i <= 20; i++){
					if(i == 2){
						Message message = new Message(i,"message " + i,10000L);
						Cache.put(message);
						continue;
					}
					Message message = new Message(i,"message " + i,3000);
					Cache.put(message);
				}
			}
		}).start();
	}
}
